package com.ruoyi.iot.handler;

import com.ruoyi.iot.config.MqttSubscribeService;
import com.ruoyi.iot.service.MqttMessageHandler;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Service;

import jakarta.annotation.Resource;

@Service
@MqttSubscribeService(topic = "/sys/+/+/thing/service/+/set_reply")
public class CommandReplyMqttMessageHandler implements MqttMessageHandler {

    @Resource
    private RocketMQTemplate rocketMQTemplate;

    @Override
    public void process(String topic,String message) {

    }
}
